package com.htdata.iiot;

import com.htiiot.common.config.ConfigFactory;

public class Configs {
	
	public static final class KafkaConfig{
        public static final String GROUP_ID = ConfigFactory.getConfigMgr().get("kafka.consumer","group.id","kafka_")+"hdfs_6";
        public static final String BOOTSTRAP_SERVERS = ConfigFactory.getConfigMgr().get("kafka.consumer","bootstrap.servers");
        public static String TOPIC = Cmd.topic!=null?Cmd.topic:ConfigFactory.getConfigMgr().get("kafka.consumer","topic","smytest");
        public static String STATTOPIC = Cmd.stattopic!=null?Cmd.stattopic:ConfigFactory.getConfigMgr().get("kafka.consumer","devStatus","smytest");
        public static final String METADATA_BROKERS = ConfigFactory.getConfigMgr().get("kafka.consumer","metadata.broker.list");
        public static final boolean ENABLE_AUTO_COMMIT = Boolean.parseBoolean(ConfigFactory.getConfigMgr().get("kafka.consumer","enable.auto.commit"));
        public static final String AUTO_OFFSET_RESET = ConfigFactory.getConfigMgr().get("kafka.consumer","auto.offset.reset");
	       
	}

}
